package com.alibaba.cloud.client8081.config;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.SubscribableChannel;

/**
 * created by wuquan at 05/07/2021
 * ^_^ ^_^
 * 自定义输入通道
 */
public interface ClientSink {
    String INPUT = "client-input";

    /**
     * @return input channel.
     */
    @Input(ClientSink.INPUT)
    SubscribableChannel input();

}
